import logging
from datetime import datetime

from celery import shared_task

from utils.wechat import WechatTestApi

logger = logging.getLogger("celery")


@shared_task
def every_three_minutes():
    """同步redis的数据到mysql做持久化保存"""
    wechat_api = WechatTestApi()
    wechat_api.send_msg()
